package websocket


type chanMessageType int

const (
	chanMessageTypeNormal chanMessageType = 0		// 正常数据消息
	chanMessageTypeNetBroken chanMessageType = 1	// 网络中断
)

// socket 与 MQ 的通信元数据
type chanMessage struct {
	Fd uint64
	Data []byte
	messageType chanMessageType
}


type MessageProcessor interface {
	OnMessage(*Session, []byte)
	OnNetworkBroken(session *Session)
}